package com.leo.jdkcore.kafka;

import org.apache.kafka.clients.consumer.ConsumerRecord;

public class KafkaStringMsgHandler implements KafkaMsgHandler<Integer,String> {

	@Override
	public void handlerMsg(String message, ConsumerRecord<Integer, String> record) {
		
	}

	@Override
	public boolean canPoll() {
		return true;
	}
}
